collectAsyncFlow

fun <T> Task<CommonFlow<T>>.collectAsyncFlow(stream: (T) -> Unit, error: (ClientException) -> Unit, scope: CoroutineScope = ContextScope.get(DispatchersProvider.Default)): CommonFlow.Job